// 云函数入口文件
const cloud = require('wx-server-sdk')
const got = require('got')
const winner=5; //中奖人数
cloud.init({
  env:'online-00000'
})

const db=cloud.database()
const _=db.command;

// 云函数入口函数
exports.main = async (event, context) => {
  const wxContext = cloud.getWXContext()
  let pro1=await db.collection('joiner')
    .aggregate()
    .sample({
      size: winner
    }).end();

  let list=pro1.list;
  let tasks=[];
  let emils=''
  for(let v of list){
    if(v.phone){
      emils+=v.phone+','
    }
    let pro = db.collection('winners').add({
      data:v
    });
    tasks.push(pro);
  }
  await Promise.all(tasks);

  //群发邮件
  let pro2 =await cloud.callFunction({
    name:'sendEmail',
    data:{
      emils,
      content: `<div style='width:80;margin: 20px auto;box-sizing: border-box;padding:20px;background:skyblue;border-radius: 30px;'>
    <p>亲爱的水友，恭喜您今日在主播选牌抽奖中幸运地成为一位中奖者；</p>
    <p>请在今天<span style='color:red'>19：00</span>之前往<span style='color:#e64340;'>《罗西基粉丝》</span>的微信小程序，或者<span style='color:#e64340;'>《罗西基选牌》</span>的QQ小程序填写相关的战网信息，以确保主播能收到您的账号信息；</p>
    <p>逾期当做放弃奖励，将由别的未中奖的水友替代名额。</p>
    <br/>
    <span><strong>注意事项:</strong></span>
    <ul><li style='color:red'>战网不能带安全令</li><li style='color:red'>请务必填写安全问题</li>
</ul></div> `
    }
  });

  return {
    email:pro2.result,
    add:tasks
  }
}